package com.gitee.xhs.joining.intervalJoin;

import com.gitee.xhs.sampleRecod.transactionRecord.Transaction;
import org.apache.flink.api.common.functions.MapFunction;

/**
 * @author BigHead
 * @date 2022/7/21 11:24
 * @description OperatorIntervalMap
 */
public class OperatorIntervalMap implements MapFunction<Transaction, Transaction> {

    private static final String SOURCE_NAME = "INTERVAL_JOIN_SOURCE";

    @Override
    public Transaction map(Transaction value) throws Exception {
        value.setStreamName(SOURCE_NAME);
        return value;
    }
}
